import { mysql } from '../db.js';

import { createConnection } from 'mysql';
import { wsSql } from '../sqlMap/wsUserSql.js';
// 连接数据库
const conn = createConnection(mysql)
conn.connect()

const addMessage = async (param) => {
    try {
        const result = await new Promise((resolve, reject) => {
            conn.query(wsSql.insert, [param.message, param.ip, param.time, param.type], (err, results, fields) => {
                if (err) reject(err);
                else resolve(results);
            });
        });
        return result[0]; // 假设我们只关心第一个结果（通常是插入的行）
    } catch (err) {
        console.error('Error adding message:', err);
        throw err; // 你可以选择重新抛出错误，以便在调用者中处理它
    }
}
const getAllMessage = async () => {
    try {
        const result = await new Promise((resolve, reject) => {
            conn.query(wsSql.queryAll, [], (err, results, fields) => {
                if (err) reject(err);
                else resolve(results);
            });
        });
        return result; // 返回查询结果
    } catch (err) {
        console.error('Error getting all messages:', err);
        throw err; // 你可以选择重新抛出错误，以便在调用者中处理它
    }
}


export {
    addMessage,
    getAllMessage,
}